package core

import (
	"gark-elastic-job/engine"
)

type JobAPI struct {
	node *JobNode
}

func NewJobAPI(node *JobNode) *JobAPI {
	return &JobAPI{node:node}
}


// 新增作业
func (jobAPI *JobAPI) AddJob(jobConf engine.GarkJobConf) {
	// todo (1)参数校验 (2)结果封装
	err := jobAPI.node.Manager.AddJob(jobConf)
	if err != nil {
		panic(err)
	}
}

// 新增群组
func (jobAPI *JobAPI) AddGroup(groupConf engine.GroupConf) {
	// todo 参数校验
	err := jobAPI.node.Manager.AddGroup(groupConf)
	if err != nil {
		panic(err)
	}
}
